/*
 *   Licensed to the Apache Software Foundation (ASF) under one
 *   or more contributor license agreements.  See the NOTICE file
 *   distributed with this work for additional information
 *   regarding copyright ownership.  The ASF licenses this file
 *   to you under the Apache License, Version 2.0 (the
 *   "License"); you may not use this file except in compliance
 *   with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 *   Unless required by applicable law or agreed to in writing,
 *   software distributed under the License is distributed on an
 *   "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 *   KIND, either express or implied.  See the License for the
 *   specific language governing permissions and limitations
 *   under the License.
 *
 */
package net.sk.cam;


import org.apache.mina.filter.codec.ProtocolEncoderOutput;
import org.apache.mina.filter.codec.ProtocolEncoderAdapter;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;

import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;

/**
 * an encoder for {@link ImageResponse} objects 
 *
 * @author <a href="http://mina.apache.org">Apache MINA Project</a>
 */
public class ImageResponseEncoder extends ProtocolEncoderAdapter {

    public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception {
        ImageResponse ir = (ImageResponse) message;
        FrameHeader fh = ir.getFh();
        BufferedImage bi = ir.getImage1();
        byte[] bytes1=null;
        int capacity =0;
        if(bi!=null){
        	bytes1= getBytes(ir.getImage1());
        	//写jpg文件测试
/*        	FileOutputStream fos=new FileOutputStream("/Users/chen4w/Documents/work/6.6/t1.jpg");
        	fos.write(bytes1);        	       	
        	fos.close();
*/        	
            fh.setLen(bytes1.length);
        	capacity+=bytes1.length;
        }else{
        	fh.setLen(0);
        }
        byte[] fhb = fh.encode();
        capacity+=fhb.length;
        
        IoBuffer buffer = IoBuffer.allocate(capacity, false);
        buffer.put(fhb);
        if(bytes1!=null){
        	buffer.put(bytes1);
        }
        buffer.flip();
        out.write(buffer);
    }

    private byte[] getBytes(BufferedImage image) throws IOException {
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        ImageIO.write(image, "jpg", baos);
        return baos.toByteArray();
    }
}
